d7d84fa3cf500b98a2015a51f754a526d2a1250f,clc/modules/wsstack/src/main/java/com/eucalyptus/ws/handlers/ServiceSinkHandler.java,ServiceSinkHandler,handleUpstream,#ChannelHandlerContext#ChannelEvent#,42

Before Change


					Messaging.dispatch( "vm://RequestQueue", msg );
					EucalyptusMessage reply = null;

					reply = ReplyQueue.getReply( msg.getCorrelationId() );
					LOG.info( EventRecord.create( this.getClass().getSimpleName(), msg.getUserId(), msg.getCorrelationId(), EventType.MSG_SERVICED, ( System.currentTimeMillis() - startTime ) ) );
					if ( reply == null ) {
						reply = new EucalyptusErrorMessageType( this.getClass().getSimpleName(), msg, "Received a NULL reply" );
					}

After Change


        requestLocal.set( ctx.getChannel( ), request );
        EucalyptusMessage msg = ( EucalyptusMessage ) request.getMessage( );
        LOG.info( EventRecord.create( this.getClass( ).getSimpleName( ), msg.getUserId( ), msg.getCorrelationId( ), EventType.MSG_RECEIVED, msg.getClass( ).getSimpleName( ) ) );
        ReplyQueue.addReplyListener( msg.getCorrelationId( ), ctx );
        Messaging.dispatch( "vm://RequestQueue", msg );
      }
    }